package com.ccc.test.mq;

import com.ccc.test.mq.sink.MsgSink;
import com.ccc.test.mq.source.MsgSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;

/**
 * @author superC
 * @version 1.0.0
 * @date 2022/7/18
 */

@SpringBootApplication(scanBasePackages = {
        "com.ccc.test",
})
@EnableBinding(value = {
        MsgSource.class,
//        MsgSink.class
})
public class RabbitmqMQApplication {
    protected static final Logger logger = LoggerFactory.getLogger(RabbitmqMQApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(RabbitmqMQApplication.class, args);
        logger.info("\r\n" +
                "*********************************************************************\r\n" +
                "\r\n" +
                "**********************启动server系统已完成*************************\r\n" +
                "\r\n" +
                "*********************************************************************");

    }

}